package com.zho.common.jms.impl;

import java.io.Serializable;

import javax.jms.JMSException;
import javax.jms.Topic;

import com.zho.common.jms.JmsTopicSender;

public class JmsTopicSenderImpl extends JmsSenderBase implements JmsTopicSender {

    private Topic topicTest1;
    private Topic topicTest2;
    
    /**
     * Send Topic 1
     * @throws JMSException
     */
    public void sendTopic1(Serializable message) throws JMSException {
    	sendMessages(message, topicTest1);
    }
    
    /**
     * Send Topic 2
     * @throws JMSException
     */
    public void sendTopic2(Serializable message) throws JMSException {
    	sendMessages(message, topicTest2);
    }    
    
	public void setTopicTest1(Topic topicTest1) {
		this.topicTest1 = topicTest1;
	}
	public void setTopicTest2(Topic topicTest2) {
		this.topicTest2 = topicTest2;
	}
   

}
